package io.mft.datasource.mq.container;

import io.mft.commons.config.mq.MqConsumer;
import io.mft.commons.function.ExecuteReturn;
import io.mft.commons.function.response.kv.KVMap;

public interface MessageProcessor {
	ExecuteReturn process(MqConsumer consumer,KVMap message);
}
